Component org.nuxeo.runtime.stream.service
In bundle org.nuxeo.runtime.stream
Documentation
The component allows to register log configurations and Log and Stream processors.
Resolution Order
822
The resolution order represents the order in which this component has been resolved by the Nuxeo Runtime
framework.
You can influence this order by adding "require" tags in your component declaration, to make sure it is resolved after another component.
Start Order
8
(Declared Start Order: -590)
The start order represents the order in which this component has been started by the Nuxeo Runtime framework.
This number is interesting to tweak if your Java component interacts with other components, and needs to be started before or after another one.
It can be changed by implementing the method "Component#getApplicationStartedOrder()" on your Java component: components are sorted according to this reference value, in increasing order.
The default value is 1000, and the repository initialization uses number 100. Negative values can also be used.
Implementation
Class:
org.nuxeo.runtime.stream.StreamServiceImpl
Services
Extension Points
Contributions
XML Source
<?xml version="1.0" encoding="UTF-8"?>
<component name="org.nuxeo.runtime.stream.service" version="1.0">
<documentation>
The component allows to register log configurations and Log and Stream processors.
</documentation>
<implementation class="org.nuxeo.runtime.stream.StreamServiceImpl" />
<service>
<provide interface="org.nuxeo.runtime.stream.StreamService" />
</service>
<extension-point name="logConfig">
<object class="org.nuxeo.runtime.stream.LogConfigDescriptor" />
</extension-point>
<extension-point name="streamProcessor">
<object class="org.nuxeo.runtime.stream.StreamProcessorDescriptor" />
</extension-point>
<extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
<streamProcessor name="metrics" class="org.nuxeo.runtime.stream.StreamMetricsProcessor" enabled="${metrics.streams.enabled:=false}">
<!-- To handle a MSK rolling upgrade we need 30min retries -->
<policy name="default" maxRetries="18" delay="15s" maxDelay="120s" continueOnFailure="false" />
<stream name="input/null" partitions="1" codec="avro" />
<computation name="stream/metrics" concurrency="1" />
</streamProcessor>
</extension>
</component>